package neu.soft.binder;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author 李博
 * 自定义消息接口，input注解是消费(括号内为配置文件中配置的消费者的名称)，output是发送
 */
public interface ChannelBinder {

    @Input("shortage-input")
    SubscribableChannel shortageInput();

    @Output("operation-supply-output")
    MessageChannel supplyOutput();

    @Input("operation-supply-input")
    SubscribableChannel purchaseInput();

    @Output("operation-warehouse-output")
    MessageChannel warehouseOutput();


    @Output("financial-supply-output")
    MessageChannel output();


}
